package com.example.model;

import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Data;
import java.util.List;
import java.util.Map;

@Data
public class CanalMessage {
    // 数据
    private List<Map<String, Object>> data;
    
    // 数据库名
    private String database;
    
    // 主键名称列表
    private List<String> pkNames;
    
    // 事件序列号
    private Long es;
    
    // 消息ID
    private Long id;
    
    // 是否是DDL语句
    @JsonProperty("isDdl")
    private boolean isDdl;
    
    // MySQL字段类型
    private Map<String, String> mysqlType;
    
    // 旧数据
    private List<Map<String, String>> old;
    
    // SQL语句
    private String sql;
    
    // SQL类型映射
    private Map<String, Integer> sqlType;
    
    // 表名
    private String table;
    
    // 时间戳
    private Long ts;
    
    // 操作类型
    private String type;
} 